package cn.iocoder.yudao.module.forward.mqtt;

import cn.iocoder.yudao.module.forward.mqtt.MqttInfo;

public interface MessageHandler {
    void handleMessage(MqttInfo mqttInfo, String topic, String data) throws Exception;

    default boolean verifyMessage(String data) {
        return true;
    }
}
